package cn.itcast.model.multithread.water;

/**
 * ClassName: PStreamMain  
 * (并行流水线分段测试)
 * @author zhangtian  
 * @version
 */
public class PStreamMain {
	public static void main(String[] args) {
		new Thread(new Plus()).start();
		new Thread(new Multiply()).start();
		new Thread(new Div()).start();
		
		for(int i = 1; i <= 1000 ; i++) {
			for(int j = 1; j <= 1000; j++) {
				Msg msg = new Msg() ;
				msg.i = i ;
				msg.j = j ;
				msg.orgStr = "((" + i + "+" + j + ")*" + i + ")/2" ;
				Plus.bq.add(msg) ;
			}
		}
	}
}
